package com.example.firstjavamqtt.controller;

import com.example.firstjavamqtt.consumer.MqttConsumer;
import org.springframework.web.bind.annotation.*;

//@RestController
//@RequestMapping("/test")
//public class TestController {
//
//    /**
//     * 测试推送消息
//     */
//    @ResponseBody
//    @GetMapping(value = "/push/{topic}/{msg}")
//    public Object push(@PathVariable String topic,@PathVariable String msg) {
//        //这里到时候调用发送给客户端的硬件处理
//        //思路逻辑 前端调用java接口 java接口发布消息给订阅的硬件接收
//        MqttConsumer.publish(topic, msg);
//        return "测试成功";
//    }
//
//
//}
